package com.spark.test.day10

import org.apache.spark.rdd.RDD

object CalculateUtil {

  def calculateIncome(fields : RDD[Array[String]]) = {
    // 将数据计算后写入Redis
  }

  def calculateItem(fields : RDD[Array[String]]) = {

  }

  def calculateZone(fields : RDD[Array[String]]) = {

  }
}
